#include "app_mqtt.h"
#include <unistd.h>
#include "log/log.h"

int mqttRcvCallback(char *json) {
    log_debug("处理接收的远程消息，消息内容：%s", json);
    return 0;
}

int main(int argc, char const *argv[])
{
    // 初始化mqtt
    app_mqtt_init();
    // 注册接收回调
    app_mqtt_registerRcvCallback(mqttRcvCallback);
    // 发送消息
    char *message = "{\"conn_type\":1,\"id\":\"5858\",\"msg\":\"61626364\"}";
    app_mqtt_send(message);

    // 等待mqtt消息
    sleep(1000);

    app_mqtt_close();

    return 0;
}
